package com.demo.qqClient.service;

import java.util.HashMap;

/**
 * 管理 客户端连接服务端的 线程
 * @author gy
 * @date 2022/5/5
 */
public class ManageClientConnectServerThread {
    /**
     * key：userId
     * value：线程
     */
    private static HashMap<String,ClientConnectServerThread> hashMap = new HashMap<>();

    /**
     * 将某个用户的线程加入到集合中去进行管理
     * @param userId
     * @param clientConnectServerThread
     */
    public static void addClientConnectServerThread(String userId,ClientConnectServerThread clientConnectServerThread){
        hashMap.put(userId,clientConnectServerThread);
    }

    /**
     * 通过 userId 获取 线程
     * @param userId
     * @return
     */
    public static ClientConnectServerThread getClientConnectServerThread(String userId){
        return hashMap.get(userId);
    }
}
